package com.mzj.eagle.jobs.heartbeat.repository.impl;

import org.elasticsearch.client.RestHighLevelClient;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Repository;

import com.mzj.eagle.jobs.common.EsRestClientRepositoryImpl;
import com.mzj.eagle.jobs.heartbeat.entity.HeartbeatEmqEs;
import com.mzj.eagle.jobs.heartbeat.repository.HeartbeatEsRepository;

/**
 * 心跳Repository组件实现
 * @author Administrator
 *
 */
@Repository
public class HeartbeatEsRepositoryImpl 
				extends EsRestClientRepositoryImpl<HeartbeatEmqEs,String> 
			implements HeartbeatEsRepository  {

	@Autowired
	private RestHighLevelClient client;
	
	@Override
	public RestHighLevelClient getEsClient() {
		return client;
	}

}
